package Repositorio;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import Dados.Secretaria;

public class RepositorioSecretaria {
	private Statement stmt;
	private String sqlStatement;
	public RepositorioSecretaria() {
		stmt = Conexao.getInstance().stmt;
	}
	public void cadastrarSecretaria(Secretaria sec) throws SQLException {
		RepositorioUsuario repUsuario = new RepositorioUsuario();
		if(!repUsuario.verificarUsuario(sec.getCpf())) {
			repUsuario.cadastrarUsuario(sec);
		}
		sqlStatement = "INSERT INTO Secretaria VALUES('"+sec.getCpf()+"')";
		stmt.executeUpdate(sqlStatement);
	}
	public void editarSecretaria(Secretaria sec) throws SQLException {
		RepositorioUsuario repUsuario = new RepositorioUsuario();
		repUsuario.editarUsuario(sec);
	}
	public void removerSecretaria(String cpf) throws SQLException {
		RepositorioUsuario repUsuario = new RepositorioUsuario();
		sqlStatement = "DELETE FROM Secretaria WHERE cpf='"+cpf+"'";
		stmt.executeUpdate(sqlStatement);
		repUsuario.removerUsuario(cpf);
	}
	public Secretaria consultarSecretaria(String cpf) throws SQLException {
		RepositorioUsuario repUsuario = new RepositorioUsuario();
		Secretaria admin = new Secretaria(repUsuario.consultarUsuario(cpf));
		return admin;
	}
	public boolean verificarSecretaria(String cpf) throws SQLException {
		boolean ret;
		sqlStatement = "SELECT * FROM Secretaria WHERE cpf='"+cpf+"'";
		ResultSet rs = stmt.executeQuery(sqlStatement);
		if(rs.next()) {
			ret = true;
		} else {
			ret = false;
		}
		return ret;
	}
};
